Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / backend / local_message_retention.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""Local-only age-based deletion of stored LXMF rows (this device, no network signal)."""

Tff7b72import T7ee787logging

Tff7b72from T7ee787collectionsT7ee787.T7ee787abc Tff7b72import Te6edf3Callable

Te6edf3log Tff7b72= Te6edf3loggingTff7b72.Td2a8ffgetLoggerTb4b4b4(Tff7b72__name__Tb4b4b4)

Te6edf3UNIT_DAYS Tff7b72= Ta5d6ff"Ta5d6ffdaysTa5d6ff"

Te6edf3UNIT_MONTHS Tff7b72= Ta5d6ff"Ta5d6ffmonthsTa5d6ff"

Te6edf3SECONDS_PER_DAY Tff7b72= T79c0ff86400

Te6edf3SECONDS_PER_MONTH Tff7b72= T79c0ff30 Tff7b72* Te6edf3SECONDS_PER_DAY

Te6edf3RETENTION_CHECK_INTERVAL_SECONDS Tff7b72= T79c0ff3600

Te6edf3LOCAL_RETENTION_STARTUP_GRACE_SECONDS Tff7b72= T79c0ff120

Te6edf3MAX_VALUE_DAYS Tff7b72= T79c0ff10_000

Te6edf3MAX_VALUE_MONTHS Tff7b72= T79c0ff120

Tff7b72def Td2a8ffnormalize_unitTb4b4b4(Te6edf3rawTb4b4b4: Tffa657str Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

Te6edf3s Tff7b72= Tb4b4b4(Te6edf3raw Tff7b72or Te6edf3UNIT_DAYSTb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)Tff7b72.Td2a8fflowerTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3s Tff7b72in Tb4b4b4(Ta5d6ff"Ta5d6ffmonthTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffmonthsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffmoTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffmTa5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3UNIT_MONTHS

Tff7b72return Te6edf3UNIT_DAYS

Tff7b72def Td2a8ffretention_window_secondsTb4b4b4(Te6edf3valueTb4b4b4: Tffa657intTb4b4b4, Te6edf3unitTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3v Tff7b72= Tffa657intTb4b4b4(Te6edf3valueTb4b4b4)

Tff7b72except Tb4b4b4(Tf85149TypeErrorTb4b4b4, Tf85149ValueErrorTb4b4b4)Tb4b4b4:

Te6edf3v Tff7b72= T79c0ff1

Te6edf3u Tff7b72= Te6edf3normalize_unitTb4b4b4(Te6edf3unitTb4b4b4)

Tff7b72if Te6edf3u Tff7b72== Te6edf3UNIT_MONTHSTb4b4b4:

Tff7b72return Tffa657maxTb4b4b4(T79c0ff1Tb4b4b4, Tffa657minTb4b4b4(Te6edf3vTb4b4b4, Te6edf3MAX_VALUE_MONTHSTb4b4b4)Tb4b4b4) Tff7b72* Te6edf3SECONDS_PER_MONTH

Tff7b72return Tffa657maxTb4b4b4(T79c0ff1Tb4b4b4, Tffa657minTb4b4b4(Te6edf3vTb4b4b4, Te6edf3MAX_VALUE_DAYSTb4b4b4)Tb4b4b4) Tff7b72* Te6edf3SECONDS_PER_DAY

Tff7b72def Td2a8fflocal_message_retention_cutoff_tsTb4b4b4(Te6edf3nowTb4b4b4: Tffa657floatTb4b4b4, Te6edf3valueTb4b4b4: Tffa657intTb4b4b4, Te6edf3unitTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Tffa657floatTb4b4b4:

Tff7b72return Tffa657floatTb4b4b4(Te6edf3nowTb4b4b4) Tff7b72- Tffa657floatTb4b4b4(Te6edf3retention_window_secondsTb4b4b4(Te6edf3valueTb4b4b4, Te6edf3unitTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffapply_local_message_retentionTb4b4b4(

Te6edf3messagesTb4b4b4,

Te6edf3cancel_outboundTb4b4b4: Te6edf3CallableTb4b4b4[Tb4b4b4[Tffa657bytesTb4b4b4]Tb4b4b4, Tff7b72NoneTb4b4b4] Tff7b72| Tff7b72NoneTb4b4b4,

Tff7b72*Tb4b4b4,

Te6edf3valueTb4b4b4: Tffa657intTb4b4b4,

Te6edf3unitTb4b4b4: Tffa657strTb4b4b4,

Te6edf3nowTb4b4b4: Tffa657floatTb4b4b4,

Tb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

T8b949e"""Delete local LXMF message rows older than the retention window.

Does not contact peers; only removes rows from the local database.

"""

Te6edf3cutoff Tff7b72= Te6edf3local_message_retention_cutoff_tsTb4b4b4(Te6edf3nowTb4b4b4, Te6edf3valueTb4b4b4, Te6edf3unitTb4b4b4)

Te6edf3hashes Tff7b72= Te6edf3messagesTff7b72.Td2a8fflist_message_hashes_with_timestamp_beforeTb4b4b4(Te6edf3cutoffTb4b4b4)

Tff7b72if Tff7b72not Te6edf3hashesTb4b4b4:

Tff7b72return T79c0ff0

Tff7b72if Te6edf3cancel_outbound Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:

Tff7b72for Te6edf3h Tff7b72in Te6edf3hashesTb4b4b4:

Tff7b72if Tff7b72not Te6edf3h Tff7b72or Tffa657lenTb4b4b4(Te6edf3hTb4b4b4) Tff7b72% T79c0ff2 Tff7b72!= T79c0ff0Tb4b4b4:

Tff7b72continue

Tff7b72tryTb4b4b4:

Te6edf3cancel_outboundTb4b4b4(Tffa657bytesTff7b72.Td2a8fffromhexTb4b4b4(Te6edf3hTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3excTb4b4b4: T8b949e# noqa: BLE001

Te6edf3logTff7b72.Td2a8ffdebugTb4b4b4(Ta5d6ff"Ta5d6fflocal_message_retention cancel_outbound: Tffd700%sTa5d6ff"Tb4b4b4, Te6edf3excTb4b4b4)

Te6edf3messagesTff7b72.Td2a8ffdelete_lxmf_messages_by_hashesTb4b4b4(Te6edf3hashesTb4b4b4)

Te6edf3messagesTff7b72.Td2a8ffprune_conversation_metadata_for_peers_with_no_messagesTb4b4b4(Tb4b4b4)

Tff7b72return Tffa657lenTb4b4b4(Te6edf3hashesTb4b4b4)